package com.x.rocketmq;

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.cloud.context.config.annotation.RefreshScope;
import org.springframework.context.annotation.Configuration;

/**
 * @author xjk
 * @date 2025-07-03
 */
@Data
@Configuration("rmqConfig")
@AllArgsConstructor
@NoArgsConstructor
@RefreshScope
@ConfigurationProperties(prefix = "rmq")
public class RmqConfig {

  /** rocketmq server地址 */
  String serverUrl;

  RmqTopic topic;
  RmqGroup group;

  /** 消息最大失败次数 */
  Integer maxFailTimes;







  @Data
  public static class RmqTopic{
    private String pushTest;
  }

  @Data
  public static class RmqGroup{
    private String pushTest;
  }

}
